package com.ydd.common.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

//import com.ydd.app.bean.output.WeixinAccessTokenBean;

/**
 * HTTP工具类
 * 
 * @author lixiangyang
 * 
 */
public class HttpUtils {

	private static Log log = LogFactory.getLog(HttpUtils.class);
	
	/**
	 * 定义编码格式 UTF-8
	 */
	public static final String URL_PARAM_DECODECHARSET_UTF8 = "UTF-8";
	
	/**
	 * 定义编码格式 GBK
	 */
	public static final String URL_PARAM_DECODECHARSET_GBK = "GBK";
	
	private static final String URL_PARAM_CONNECT_FLAG = "&";
	
	private static final String EMPTY = "";

	private static MultiThreadedHttpConnectionManager connectionManager = null;

	private static int connectionTimeOut = 25000;

	private static int socketTimeOut = 25000;

	private static int maxConnectionPerHost = 20;

	private static int maxTotalConnections = 20;

	private static HttpClient client;

	static{
		connectionManager = new MultiThreadedHttpConnectionManager();
		connectionManager.getParams().setConnectionTimeout(connectionTimeOut);
		connectionManager.getParams().setSoTimeout(socketTimeOut);
		connectionManager.getParams().setDefaultMaxConnectionsPerHost(maxConnectionPerHost);
		connectionManager.getParams().setMaxTotalConnections(maxTotalConnections);
		client = new HttpClient(connectionManager);
	}
	
	/**
	 * POST方式提交数据
	 * @param url
	 * 			待请求的URL
	 * @param params
	 * 			要提交的数据
	 * @param enc
	 * 			编码
	 * @return
	 * 			响应结果
	 * @throws IOException
	 * 			IO异常
	 */
	public static String URLPost(String url, Map<String, String> params, String enc){

		String response = EMPTY;		
		PostMethod postMethod = null;
		try {
			postMethod = new PostMethod(url);
			postMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
			//将表单的值放入postMethod中
			Set<String> keySet = params.keySet();
			for(String key : keySet){
				String value = params.get(key);
				postMethod.addParameter(key, value);
			}			
			//执行postMethod
			int statusCode = client.executeMethod(postMethod);
			if(statusCode == HttpStatus.SC_OK) {
				response = postMethod.getResponseBodyAsString();
			}else{
				log.error("响应状态码 = " + postMethod.getStatusCode());
			}
		}catch(HttpException e){
			log.error("发生致命的异常，可能是协议不对或者返回的内容有问题", e);
			e.printStackTrace();
		}catch(IOException e){
			log.error("发生网络异常", e);
			e.printStackTrace();
		}finally{
			if(postMethod != null){
				postMethod.releaseConnection();
				postMethod = null;
			}
		}
		
		return response;
	}
	
	/**
	 * GET方式提交数据
	 * @param url
	 * 			待请求的URL
	 * @param params
	 * 			要提交的数据
	 * @param enc
	 * 			编码
	 * @return
	 * 			响应结果
	 * @throws IOException
	 * 			IO异常
	 */
	public static String URLGet(String url, Map<String, String> params, String enc){

		String response = EMPTY;
		GetMethod getMethod = null;		
		StringBuffer strtTotalURL = new StringBuffer(EMPTY);
		
	    if(strtTotalURL.indexOf("?") == -1) {
	      strtTotalURL.append(url).append("?").append(getUrl(params, enc));
	    } else {
	    	strtTotalURL.append(url).append("&").append(getUrl(params, enc));
	    }
		try {
		    log.debug("GET请求URL = \n" + strtTotalURL.toString());
			getMethod = new GetMethod(strtTotalURL.toString());
			getMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
			//执行getMethod
			int statusCode = client.executeMethod(getMethod);
			if(statusCode == HttpStatus.SC_OK) {
				response = getMethod.getResponseBodyAsString();
			}else{
				log.debug("响应状态码 = " + getMethod.getStatusCode());
			}
		}catch(HttpException e){
			log.error("发生致命的异常，可能是协议不对或者返回的内容有问题", e);
			e.printStackTrace();
		}catch(IOException e){
			log.error("发生网络异常", e);
			e.printStackTrace();
		}finally{
			if(getMethod != null){
				getMethod.releaseConnection();
				getMethod = null;
			}
		}
		
		return response;
	}	

	/**
	 * 据Map生成URL字符串
	 * @param map
	 * 			Map
	 * @param valueEnc
	 * 			URL编码
	 * @return
	 * 			URL
	 */
	public static String getUrl(Map<String, String> map, String valueEnc) {
		
		if (null == map || map.keySet().size() == 0) {
			return (EMPTY);
		}
		StringBuffer url = new StringBuffer();
		Set<String> keys = map.keySet();
		for (Iterator<String> it = keys.iterator(); it.hasNext();) {
			String key = it.next();
			if (map.containsKey(key)) {
				String val = map.get(key);
				String str = val != null ? val : EMPTY;
				try {
					str = URLEncoder.encode(str, valueEnc);
				} catch (UnsupportedEncodingException e) {
					e.printStackTrace();
				}
				url.append(key).append("=").append(str).append(URL_PARAM_CONNECT_FLAG);
			}
		}
		String strURL = EMPTY;
		strURL = url.toString();
		if (URL_PARAM_CONNECT_FLAG.equals(EMPTY + strURL.charAt(strURL.length() - 1))) {
			strURL = strURL.substring(0, strURL.length() - 1);
		}
		
		return (strURL);
	}
	
//	public static void main(String[] args) throws Exception{ 
//		Map map = new HashMap();
//    	map.put("grant_type","client_credential");
//    	map.put("appid","wxd4a21f7e8cfe7ffb");
//    	map.put("secret","fc5e2f301d216a19112cbb9f89f8b31b");
//    	HttpUtils utils = new HttpUtils();
//    	utils.URLGet("https://api.weixin.qq.com/cgi-bin/token",map,"UTF-8");
// //   	System.out.println(getUrl(map,"UTF-8"));
// //   	System.out.println(utils.URLGet("https://api.weixin.qq.com/cgi-bin/token",map,"UTF-8"));
//    	
//    	JSONArray array = JSONArray.fromObject("["+utils.URLGet("https://api.weixin.qq.com/cgi-bin/token",map,"UTF-8")+"]");//先读取串数组
//    	Object[] o = array.toArray();                //转成对像数组
//    	System.err.println(o.length);            
//    	JSONObject obj = JSONObject.fromObject(o[0]);//再使用JsonObject遍历一个个的对像
//    	WeixinAccessTokenBean oo = (WeixinAccessTokenBean)obj.toBean(obj,WeixinAccessTokenBean.class);//指定转换的类型，但仍需要强制转化-成功
//    	map = new HashMap();
//    	map.put("access_token",oo.getAccess_token());
//    	map.put("type","jsapi");
//    	System.err.println(utils.URLGet("https://api.weixin.qq.com/cgi-bin/ticket/getticket",map,"UTF-8"));    
//    	array = JSONArray.fromObject("["+utils.URLGet("https://api.weixin.qq.com/cgi-bin/ticket/getticket",map,"UTF-8")+"]");//先读取串数组
//    	o = array.toArray();                //转成对像数组 
//    	obj = JSONObject.fromObject(o[0]);//再使用JsonObject遍历一个个的对像
//    	WeixinAccessTokenBean finalReturn = (WeixinAccessTokenBean)obj.toBean(obj,WeixinAccessTokenBean.class);//指定转换的类型，但仍需要强制转化-成功
//    	String ss2 = finalReturn.getTicket();  
//    	System.err.println(ss2);
//	}
}
